package com.senbai.springlearning.threadlearn.service;

import com.senbai.springlearning.threadlearn.bean.OrderQuery;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.LinkedBlockingQueue;

@Service
public class QueryService {

    /** LinkedBlockingQueue是一个阻塞的队列,内部采用链表的结果,通过两个ReenTrantLock来保证线程安全
     * LinkedBlockingQueue与ArrayBlockingQueue的区别
     * ArrayBlockingQueue默认指定了长度,而LinkedBlockingQueue的默认长度是Integer.MAX_VALUE,也就是无界队列,在移除的速度小于添加的速度时，容易造成OOM。
     * ArrayBlockingQueue的存储容器是数组,而LinkedBlockingQueue是存储容器是链表
     * 两者的实现队列添加或移除的锁不一样，ArrayBlockingQueue实现的队列中的锁是没有分离的，即添加操作和移除操作采用的同一个ReenterLock锁，而LinkedBlockingQueue实现的队列中的锁是分离的，其添加采用的是putLock，移除采用的则是takeLock，这样能大大提高队列的吞吐量，也意味着在高并发的情况下生产者和消费者可以并行地操作队列中的数据，以此来提高整个队列的并发性能。
     */
    public static LinkedBlockingQueue<OrderQuery> queue = new LinkedBlockingQueue<>();

    public Map<String,Object> addToQuery(OrderQuery orderQuery){
        Map<String,Object> queryResult = new HashMap<>();
        queue.add(orderQuery);
        return queryResult;
    }

    @Scheduled(initialDelay=10, fixedRate=10)
    public void queryBatch() {
        int size = queue.size();
        System.out.println("queue的长度是" + size);
        for (int i = 0; i <= size; i++) {
            System.out.println("hello" + i);
        }
    }
}
